package cn.mq.service;

import java.util.function.BiConsumer;

/**
 * 消息接口
 *
 * @author zhanghui145
 * @date 2022/1/14 9:37
 * @since 1.0.0
 */
public interface MqService {

    void send(String topic, String message);

    void subscribe(String topic, BiConsumer<String, String> consumer);
}
